package com.njbdqn.shoppings.hotgood

import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala._
import org.apache.flink.table.api.EnvironmentSettings
import org.apache.flink.table.api.scala._

object HotItems {
  def main(args: Array[String]): Unit = {

   object AdCount {
     def main(args: Array[String]): Unit = {
       val env = StreamExecutionEnvironment.getExecutionEnvironment
           env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
           env.setParallelism(1)
       val settings = EnvironmentSettings.newInstance()
            .useBlinkPlanner() // Flink 10的时候默认是用的useOldPlanner 11就改为了BlinkPlanner
            .inStreamingMode()
            .build()
       val tabEnv = StreamTableEnvironment.create(env,settings)
       println("Hello")
       println("Hello，hehe")
       env.execute("test")
     }
   }
  }
}
